package tianrun.ziguan.api.calculate.config.service.datainfo.impl;

import com.baomidou.dynamic.datasource.annotation.DS;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import org.springframework.stereotype.Service;
import tianrun.ziguan.api.calculate.config.constant.MysqlConstant;
import tianrun.ziguan.api.calculate.config.dao.datainfo.TDatainfoLabelLineMapper;
import tianrun.ziguan.api.calculate.config.entity.datainfo.TDatainfoLabelLine;
import tianrun.ziguan.api.calculate.config.service.datainfo.TDatainfoLabelLineService;

import java.util.List;
@Service
@DS(MysqlConstant.mysql_MqttToKafka)
public class TDatainfoLabelLineServiceImpl extends ServiceImpl<TDatainfoLabelLineMapper, TDatainfoLabelLine> implements TDatainfoLabelLineService {
    @Override
    public List<TDatainfoLabelLine> getByAssetLineId(Long assetLineId) {
        return list(Wrappers.<TDatainfoLabelLine>lambdaQuery().eq(TDatainfoLabelLine::getDatainfoAssetLineId,assetLineId));
    }
}
